package com.jzr.bedside.db1.service;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

/**
 * Created by lijunnan on 2017/7/20.
 */
@Service
public class RabbitMqService {

    public static final String TASK_PUSH_REDIS_CHANNEL = "TASK_MESSAGE";

    @Qualifier("getRabbitTemplate")
    @Autowired
    private RabbitTemplate taskRabbitTemplate;
    @Value("#{taskExchange.name}")//交换机的名称
    private String exchangeName;

    /**
     * 监听事件，只要队列的名称是taskNoticeQueue.name的值一樣的就能监听
     * @param ss 传递的数据
     */
//    @RabbitListener(queues = "#{taskNoticeQueue.name}")
//    public void receiveEvent4Notice(String ss) {
//        System.out.println("我是监听消息的，我监听成功了值："+ss);
//    }

    /**
     * @param ss 就是要发送的一个数据
     */
    public void invokeTaskEvent(String ss) {
        taskRabbitTemplate.convertAndSend(exchangeName, "",ss);
    }

}
